package com.example.mq.common;

import com.example.mq.mqserver.core.BasicProperties;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {

    //每次服务器收到消息后，调用
    //通过这个方法，把消息推送给消费者
    void handleDelivery(String consumerTag, BasicProperties properties, byte[] body) throws MqException, IOException;

}
